from multiprocessing import Queue

# 创建一个队列，可以指定队列大小，如果不写默认队列是无限的
q = Queue(3)
print(q.qsize())
for i in range(5):
    if not q.full():
        q.put('消息%s'%i)
    else:
        print('队列已满无法继续插入元素')
        break
print(q.qsize())
for i in range(q.qsize()):
    if not q.empty():
        res = q.get()
        print(res)
    else:
        print('对列中暂无元素，无法继续获取！！！')
        break

